package com.sls.mall.order.rabbit;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.core.RabbitTemplate;

/**
 * @author lixue
 * @Title: OrderReturnCallback
 * @ProjectName sls_mall2021
 * @Description: TODO
 * @date 2021/5/915:19
 */
public class OrderReturnCallback implements RabbitTemplate.ReturnCallback {


    /**
     *   只要消息没有投递给指定的队列，就触发这个失败回调
     *
     * @param message        投递失败的消息详细信息
     * @param replyCode      回复的状态码
     * @param replyText      回复的文本内容
     * @param exchange       当时这个消息发给哪个交换机
     * @param routingKey     当时这个消息用哪个路由键
     */
    @Override
    public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {

        System.out.println("fail message["+message+"] ==> replyCode["+replyCode+"] ==> replyText["+replyText+"] ==> exchange["+exchange+"] ==> routingKey["+routingKey+"]");
    }
}
